package com.bjbn.aesbcommonapi.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import java.util.List;

@Configuration
@ConfigurationProperties(prefix = "aesb.rocketmq")
@Data
public class RocketMQConfig {
    private String namesrvAddr;
    private String accessKey;
    private String secretKey;
    private Boolean useTls;
    private List<GroupConfig> groups;

    @Data
    public static class GroupConfig {
        private String consumerGroup;
        private List<TopicMapping> topics;
    }

    @Data
    public static class TopicMapping {
        private String source;
        private String target;
    }
} 